package com.doit.day01;

import redis.clients.jedis.Jedis;

import java.util.Random;

public class ConsumerDemo {
    public static void main(String[] args) throws InterruptedException {
        //redis对象
        Jedis redis = new Jedis("linux01", 6379);



        while (true){
            //需要搞一个缓冲区  ==》 list
            redis.rpoplpush("producer","buffer");
            //消费buffer中的task
            int i = new Random().nextInt();
            //在消费代码
            String task = redis.rpop("buffer");
            //如果随机数 能够被3整除，就代表任务失败
            if (i %3 == 0 ){
                System.out.println("将失败的代码放回到缓冲区"+task);
                //如果任务失败，就放回到缓冲区
                redis.lpush("buffer",task);
            }else {
                System.out.println("任务完成"+task);
            }

            Thread.sleep(3000);
        }





    }
}
